package cn.jbooter.mq.autoconfigure.rocketmq.coms;

import org.apache.rocketmq.client.producer.MQProducer;


/**
 * 创建rocket producer
 * @author HeJian
 *
 */
public interface IRocketProducer {
	
	/**
	 * producer的初始化
	 * @throws Exception
	 */
	public void init() throws Exception;
	
	/**
	 * Producer的销毁
	 */
	public void destroy()throws Exception;
	
	/**
	 * 获取producer
	 * @return
	 */
	public MQProducer getProducer();
	
	
}
